import aioredis
import asyncio

async def fetch_data():
    # 创建Redis客户端
    redis = await aioredis.create_redis_pool('redis://localhost:16379')

    # 异步设置和获取数据
    await redis.set('my_key', 'value')
    value = await redis.get('my_key',encoding='utf-8')
    print(value)
    redis.close()
    # 等待Redis连接完全关闭
    await redis.wait_closed()

# 运行协程
asyncio.run(fetch_data())